732e6da4f924a99ba5fbddf656436fc1bd62668f,src/main/java/org/apache/sysml/runtime/instructions/spark/WriteSPInstruction.java,WriteSPInstruction,processMatrixWriteInstruction,#SparkExecutionContext#String#OutputInfo#,174
Before Change
//piggyback nnz computation on actual write
Accumulator<Double> aNnz = null;
if( !mc.nnzKnown() ) {
aNnz = sec.getSparkContext().accumulator(0L);
in1 = in1.mapValues(new ComputeBinaryBlockNnzFunction(aNnz));
}
After Change
//piggyback nnz computation on actual write
LongAccumulator aNnz = null;
if( !mc.nnzKnown() ) {
aNnz = sec.getSparkContext().sc().longAccumulator("nnz");
in1 = in1.mapValues(new ComputeBinaryBlockNnzFunction(aNnz));
}